package org.example.hello2_workPattern;

import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 消费者(工作模式)，rabbitTemplate直接往这个队列发信息，多个消费者往这个队列获取信息
 *
 * 工作模式是指多个相互竞争的消费者发送消息的模式，它包含一个生产者、两个消费者和一个队列。
 * 两个消费者同时绑定到一个队列上去，当消费者获取消息处理耗时任务时，空闲的消费者从队列中获取b并消费队列。
 */
@Component
public class WorkCoustmer {

    @RabbitListener(queuesToDeclare = {@Queue("work_queue")})
    public void receiveMessage1(String body) {
        System.out.println("Work-消费者[1]收到消息，内容为：" + body);
    }


    @RabbitListener(queuesToDeclare = {@Queue("work_queue")})
    public void receiveMessage2(String body) {
        System.out.println("Work-消费者[2]收到消息，内容为：" + body);
    }

}

